package main

import (
	"beego_benchu/services/mq"
	"fmt"
)

func main() {
	mq.ConsumerDlx("fyouku.dlx.a", "fyouku_dlx_a", "fyouku.dlx.b", "fyouku_dlx_b", 10000, callback)
}

func callback(s string) {
	fmt.Print("msg is : %s\n", s)
}
